package data.platform.common.service.query;

import data.platform.common.stream.aggregates.RulePoint;
import reactor.core.publisher.Flux;

import java.time.LocalDateTime;

public interface RulePointQueryService {

    Flux<RulePoint> query(LocalDateTime beginTime, LocalDateTime endTime, String ruleId);
}
